package com.dragon.flow.vo.disruptor;

import lombok.Data;

import java.io.Serializable;

/**
 * @title: 节点缓存消息
 * @author: bruce.liu
 * @since: 2024/8/8 23:53
 */
@Data
public class CacheActivityMessage implements Serializable {
    //流程实例id
    private String processInstanceId;
    //事件类型
    private String eventType;
    /**
     * 当前节点id
     */
    private String activityId;
    //是否是任务节点
    private boolean flag = false;

    public CacheActivityMessage(String processInstanceId, String eventType, String activityId) {
        this.processInstanceId = processInstanceId;
        this.eventType = eventType;
        this.activityId = activityId;
    }

    public CacheActivityMessage(String processInstanceId, String eventType, String activityId, boolean flag) {
        this.processInstanceId = processInstanceId;
        this.eventType = eventType;
        this.activityId = activityId;
        this.flag = flag;
    }
}
